package com.chaos.eurekaproducer.rabbitmq;

import org.springframework.amqp.core.Message;
import org.springframework.amqp.rabbit.retry.MessageRecoverer;
import org.springframework.context.annotation.Configuration;

/**
 * @author liaopeng
 * @title: MyMessageRecoverer
 * @projectName eureka-producer
 * @description: TODO
 * @date 2021/12/20下午4:42
 */
@Configuration
public class MyMessageRecoverer implements MessageRecoverer {

    @Override
    public void recover(Message message, Throwable throwable) {
        
        System.out.println("消息失败了");
    }
}
